-
Notifications
You must be signed in to change notification settings - Fork 194
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Enable minibatcher #701
Enable minibatcher #701
Conversation
9fdb219
to
98163f5
Compare
111409f
to
2cbfeed
Compare
ChainState core.IndexedChainState | ||
AssignmentCoordinator core.AssignmentCoordinator |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks for cleaning this up!
|
||
o.finalizer.Start(ctx) | ||
|
||
go func() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should we keep this loop in minibatcher (and Start
method)?
Looks like we moved it here to have signalLiveness
interweaved in the loop, but signaling liveness from the high level component seems sufficient
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Don't we need to signalLiveness on some sort of reoccurring loop where work is being done?
16f1f3b
to
1458f9c
Compare
Refactor batcher/minibatcher creation to use generic interface Fix integration test Fix tests Update batcher interface type cast Move minibatcher tablename check to earlier init phase Make minibatcher table name optional Add info output at startup Lint Remove log output Rename MinibatchStore to Batchstore Remove generic batch/minibatcher interface Add orchestrator abstraction Add metrics Add finalizer Refactor and consolidate encoding client/streamer init Revert batcher to original Move minibatcher branch logic to main Move finalizer, encodingstreamer, chain state, assignment mgr into orchestrator Add batchConfirmer to orchestrator Move signalLiveness into orchestrator Add transactionMgr startup to orchestrator Lint Lint Lint Lint
1458f9c
to
0b5e119
Compare
bc881cb
to
67d26ec
Compare
046755a
to
4497dfc
Compare
Abandoned. RIP Minibatcher |
Why are these changes needed?
Checks